package lx.springBoot.activeMq;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

/**
 * Created by lx on 2017/7/10.
 */
@Component("consumer")
public class Consumer {

    private Logger logger = LoggerFactory.getLogger(getClass());

    @JmsListener(destination = ActiveMqConfig.TOPIC)
    public void receiveTopic(String mes){

        logger.info("receiveTopic ==  " + mes);
    }
}
